package com.shujia.rec.service.impl;

import com.shujia.rec.dao.KafkaDao;
import com.shujia.rec.service.LogService;
import com.shujia.util.Config;
import org.springframework.stereotype.Service;


@Service
public class LogServiceImpl implements LogService {

    private KafkaDao kafkaDao = new KafkaDao();

    @Override
    public void sendLog(String value) {
        kafkaDao.sendLog(Config.getString("kafka.topic"), null, value);
    }
}
